package cn.itcast.function;

import cn.itcast.bean.CleanBean;
import org.apache.flink.api.java.functions.KeySelector;

/**
 * 根据证券代码进行分组（个股和指数）
 */
public class KeyFunction implements KeySelector<CleanBean,String> {

    @Override
    public String getKey(CleanBean cleanBean) throws Exception {
        return cleanBean.getSecCode();
    }
}
